import KafkaSink.Base
import org.apache.flink.api.common.functions.FilterFunction

/**
 *
 * @author Spring_Hu
 * @date 2021/10/10 21:24
 */
object filter extends Base {
  def main(args: Array[String]): Unit = {
    run{
      ds.filter(new FilterFunction[Int] {
        override def filter(value: Int) = {
          value%2==0
        }
      }).print()
    }
  }

}
